package cn.stronglink.asset.module.dam.utils.dataJsonUtils.realtime.receive;

import cn.stronglink.asset.module.dam.entity.message.MsgRealTimeDatas;
import cn.stronglink.asset.module.dam.entity.message.basicMsg.DamMqMessage;
import cn.stronglink.asset.module.dam.interfaces.MsgReceiveI;
import cn.stronglink.asset.module.dam.interfaces.RealtimeDatasHandleStrategyI;

public class ThreadForReceiveUtil extends Thread {
	private  MsgRealTimeDatas damMsg;// mq消息实体
	private  RealtimeDatasHandleStrategyI service;// 处理解析后的数据
	// 构造器
	public ThreadForReceiveUtil(MsgRealTimeDatas damMsg,RealtimeDatasHandleStrategyI service) {
		this.damMsg = damMsg;
		this.service = service;
	}
	
	// 重写线程run() : service处理mq消息,解析数据
	@Override
	public void run() {
		service.handleDamDatas(damMsg);
	}
			

}
